package com.heima.kafka.consumer;

import lombok.extern.slf4j.Slf4j;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

import java.util.HashMap;

@Component
@Slf4j
public class KafkaConsumer {

    @KafkaListener(
            topics = "demo01"
    )
    public void consumer(String s){
        HashMap<Object, Object> objectObjectHashMap = new HashMap<>();
        log.info("消费者接收到信息{}",s);
    }
}
